629923bf0288f381a6d89b8249ce0e081333e3e9,software/nosql/src/main/java/brooklyn/entity/nosql/riak/RiakClusterImpl.java,RiakClusterImpl,onServerPoolMemberChanged,#Entity#,102

Before Change


                log.error("Unable to get riak name for node: {}", member.getId());
            } else {
                //flag a first node to be the first node in the riak cluster.
                if (!isFirstNodeSet.get()) {
                    nodes.put(member, riakName);
                    setAttribute(RIAK_CLUSTER_NODES, nodes);

                    ((EntityInternal) member).setAttribute(RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER, Boolean.TRUE);
                    isFirstNodeSet.set(true);

                    log.info("Adding riak node {}: {}; {} to cluster", new Object[]{this, member, getRiakName(member)});

After Change


            Preconditions.checkNotNull(riakName);

            // flag a first node to be the first node in the riak cluster.
            if (!isFirstNodeSet.getAndSet(true)) {
                nodes.put(member, riakName);
                setAttribute(RIAK_CLUSTER_NODES, nodes);